package com.wuba.rxjavademo.lyz.day0602;

import com.wuba.rxjavademo.lyz.BaseDemo;

import rx.Observable;

/**
 * Created by liyaxing on 2016/6/8.
 */
public class Demo05 extends BaseDemo{

    public static void main(String[] ss){

//        Observable.just(1,2,3,4).subscribe(mSubscriber) ;


//        Observable.create(new Observable.OnSubscribe<String>() {
//            @Override
//            public void call(Subscriber<? super String> subscriber) {
//                subscriber.onNext("ccc");
//                subscriber.onCompleted();
//            }
//        }).subscribe(mSubscriber) ;
//        Observable
//                .just(5,6,7,8)
//                .lift((Observable.Operator<Integer, Integer>) subscriber ->
//                    new Subscriber<Integer>() {
//                        @Override
//                        public void onCompleted() {
//
//                        }
//                        @Override
//                        public void onError(Throwable e) {
//
//                        }
//                        @Override
//                        public void onNext(Integer integer) {
//                            subscriber.onNext(integer + 20);
//                        }
//                    }
//                ).subscribe(mSubscriber) ;
//        Observable.just(1,2,3,4,5)
//                .map()
        Observable
                .just(1,2,3,4,5)
                .compose(new Observable.Transformer<Integer, String>() {
                    @Override
                    public Observable<String> call(Observable<Integer> integerObservable) {
                        return null;
                    }
                }) ;

    }

}
